package com.源码分析;

import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import reactor.core.publisher.Mono;

public class DoOnSuccess {

	static final Logger LOGGER = LoggerFactory.getLogger(DoonDemo.class);

	@Test
	public void testDoOnMethods() {
		Mono.just("test")
		.doOnSuccess(x -> {
			LOGGER.info("doOnSuccess: " + x);
		})
		.subscribe(x -> {
			LOGGER.info("complete: " + x);
		});
	}

}
